package com.tonghl.juc.queue_study.queueutil;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * Created by tonghl
 * 做加法
 */
public class CycliBarrierDemo {

    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier=new CyclicBarrier(7,()->{
            System.out.println("********召唤神龙");
        });

          for (int i = 1; i <=7 ; i++)
                  {
                      final int temp=i;
                      new Thread(()->
                      {
                          System.out.println(Thread.currentThread().getName()+"\t 收集到第："+temp+"龙泽");
                          try{
                              cyclicBarrier.await();
                          }catch (InterruptedException e){
                           e.printStackTrace();
                          }catch (BrokenBarrierException e){
                           e.printStackTrace();
                          }
                      },String.valueOf(i)).start();
                  }
    }
}
